package com.akaovi.chatroom;

import com.akaovi.chatroom.process.UserThread;

import java.io.IOException;
import java.net.ServerSocket;
import java.net.Socket;

/**
 * @author akaovi
 * @version 1.0
 * @description
 * @date 2022/12/7 16:34
 * @since 2022/12/7 16:34
 */
public class Main {
    public static void main(String[] args) {
        System.out.println("""
                                             \s
                             : : : : : : .   \s
                           :       :     :   \s
                           : E   : : : :     \s
                           : E               \s
                           : E     :         \s
                             :       :       \s
                               :     :       \s
                                 : : : : : . \s
                   : :   : : :             : \s
                   : E E E     : :         : \s
                   : E E E : , E   : : : :   \s
                     : : t E E : :           \s
                         E D     : : : : :   \s
                """);
        ServerSocket serverSocket = null;
        try {
            serverSocket = new ServerSocket(20000);
            System.out.println("服务启动完毕...");
            // 开始监听客户端的连接
            while (true) {
                Socket accept = serverSocket.accept();
                // 监听到用户接入，开一个线程去处理
                new Thread(new UserThread(accept)).start();
            }
        } catch (Exception e) {
            System.out.println("创建服务端失败!");
            e.printStackTrace();
        } finally {
            if (serverSocket != null) {
                try {
                    serverSocket.close();
                } catch (IOException e) {

                    e.printStackTrace();
                }
            }
        }
    }
}
